package com.wlz.pubsub;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.wlz.utils.RabbitUtils;
import lombok.extern.slf4j.Slf4j;

import java.util.Scanner;

/**
 *  发布/订阅 模式 -- 生产者
 * @author wlz
 * @date 2022-06-27  10:38 下午
 */
@Slf4j
public class WeatherBureau {

    public static void main(String[] args) throws Exception{

        Connection connection = RabbitUtils.getConnection();
        // 控制台输入
        String input = new Scanner(System.in).next();
        Channel channel = connection.createChannel();

        String exchangeName = "wlz_weather";

        // 第一个参数 为 交换机名字 , 其他参数和之前一样， (其中 交换机必须先创建，不然会报错， 选择 fanout 类型)
        channel.basicPublish(exchangeName, "", null, input.getBytes());

        log.info("发布定义模式 交换机为: {} , 发送消息成功  ",exchangeName);

        channel.close();
        connection.close();


    }
}
